package com.example.kafka;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
//import org.springframework.kafka.test.context.EmbeddedKafka;// 自动启一个kafka服务

@SpringBootApplication
//注解@EmbeddedKafka可以启动一个功能完整的Kafka服务
//@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://127.0.0.1:9092", "port=9092" })
public class SpringbootApplication {

	public static void main(String[] args) {
		SpringApplication.run(SpringbootApplication.class, args);
	}
}
